//package com.fuchuang.seckillsystem.rocketmq;
//
//import com.fuchuang.seckillsystem.entity.User;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.client.producer.SendCallback;
//import org.apache.rocketmq.client.producer.SendResult;
//import org.apache.rocketmq.spring.core.RocketMQTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//@Component
//@Slf4j
//public class UserProducer {
//
//    private static final String TOPIC = "seckill";
//
//    private static final String USER = "user";
//
//    @Autowired
//    private RocketMQTemplate rocketMQTemplate;
//
//
//    public void sendRegisterUser(User user) {
//        rocketMQTemplate.asyncSend(TOPIC + ":" + USER, user, new SendCallback() {
//            @Override
//            public void onSuccess(SendResult sendResult) {
//                System.out.println("发生成功");
//            }
//
//            @Override
//            public void onException(Throwable throwable) {
//                System.out.println("发生失败");
//            }
//        });
//    }
//
//
//}
